package com.cpic.rxjava;

public class ObservableObserverOn<T> extends Obsersable<T> {
    Obsersable<T> source;
    int threadFlag=0;//

    public ObservableObserverOn(Obsersable<T> source, int threadFlag) {
        this.source = source;
        this.threadFlag = threadFlag;
    }

    @Override
    public void subcribeObserverActual(Observer<T> observer) {
            source.subcribeObserver(new ObserverObserverOn<>(observer,threadFlag));

    }

}
